package com.kafka.comsumer.listener;

/**
 * @作者: 林江
 * @创建时间: 2024/4/2
 * @功能: 类级别的监听器
 */
//@Component
//@KafkaListener(id = "1", topics = "tow")
public class KafkaConsumerListener02 {

    //    @KafkaHandler(isDefault = true) // 当管理中的方法都无法匹配接收到消息，就会将值序列化到这个方法。
    public String one(String in) {
        System.out.println(in);
        return "消费者成功接收到消息";
    }
}
